package org.example.flinksql.test.custom;

import org.apache.flink.table.functions.ScalarFunction;
import org.example.util.Utils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;


public class TransStringFunc extends ScalarFunction {
    private static final Logger LOGGER = LoggerFactory.getLogger(TransStringFunc.class);

    public String eval(String str) {
        return Utils.str2String(str);
    }
}
